CEP，Complex event processing Wiki定義 “Complex event processing, or CEP, is event processing that co ...

JDK安裝版本要求8.0以上 tar xf jdk-8u161-linux-x64.tar.gz -C /usr/local/ mv /usr/local/{jdk1.8.0_161,jdk} ...

使用方式如上，核心就是對SourceFunction的實現 FlinkKafkaConsumerBase FlinkKafkaConsumerBase繼承RichPa ...

如果要考慮易用性和效率，使用rocksDB來替代普通內存的kv是有必要的 有了rocksdb，可以range查詢，可以支持columnfamily，可以各種壓縮 但是rocksdb本身是一個庫，是 ...

Example Program The following program is a complete, working example of streaming window word count ...

Flink在流上最大的特點，就是引入全局snapshot， CheckpointCoordinator 做snapshot的核心組件為， CheckpointCoordinator ...

參考，Flink - Generating Timestamps / Watermarks watermark，只有在有window的情況下才用到，所以在window operator前加上a ...

Flink 配置文件 對於管理員來說，差不多經常調整的就只有 conf 下的flink-conf.yaml ： 經過初步的調整，大約有以下模塊的參數（未優化） ################### ...

維度表，作為數據倉庫里面的概念，是維度屬性的集合，比如時間維、地點維; 但這里要討論流計算中的維度表問題， 流計算中維表問題和數據倉庫中有所不同，往往是因為通過agent采集到的數據比較有限 ...

SlotSharingGroup 表示不同的task可以共享slot，但是這是soft的約束，即也可以不在一個slot 默認情況下，整個StreamGraph都會用一個默認的“defaul ...